// package com.example.bootintegration.websocket;
//
// import jakarta.websocket.ClientEndpoint;
// import jakarta.websocket.CloseReason;
// import jakarta.websocket.OnClose;
// import jakarta.websocket.OnError;
// import jakarta.websocket.OnMessage;
// import jakarta.websocket.OnOpen;
// import jakarta.websocket.PongMessage;
// import jakarta.websocket.Session;
// import java.nio.ByteBuffer;
//
// @ClientEndpoint
// public class JavaxWebSocketClientEndpoint {
//
//     @OnOpen
//     public void onOpen(Session session) {
//         //连接建立
//     }
//
//     @OnClose
//     public void onClose(Session session, CloseReason reason) {
//         //连接关闭
//     }
//
//     @OnMessage
//     public void onMessage(Session session, String message) {
//         //接收文本消息
//         System.out.println("msg: " + message);
//         session.getAsyncRemote().sendText("client..");
//     }
//
//     @OnMessage
//     public void onMessage(Session session, PongMessage message) {
//         //接收pong消息
//     }
//
//     @OnMessage
//     public void onMessage(Session session, ByteBuffer message) {
//         //接收二进制消息
//     }
//
//     @OnError
//     public void onError(Session session, Throwable e) {
//         //异常处理
//     }
// }